#include <mysql/mysql.h>
#include <stdio.h>
#include <strings.h>
#include "../head/client.h"
int mysql_database(MYSQL *mysql){
    MYSQL *ret=mysql_real_connect(mysql,
                       "192.168.7.22",
                       "root",
                       "1",
                       "zhaoTest", //数据库名
                       3306,
                       NULL,
                       0
                       );
    if(ret==NULL){
        fprintf(stderr,"%s:%s\n","mysql_real_connect",mysql_error(mysql));
        exit(-1);
    }
    return 0;
}
int mysql_add(MYSQL *mysql,char *buf){//增加数据
    char query[256]={0};
    sprintf(query,"insert into user (username) values('%s');\n",buf);
    int qret=mysql_query(mysql,query);//把sql语句字符串发给服务端
    if(qret!=0){
        fprintf(stderr,"%s:%s\n","mysql_real_connect",mysql_error(mysql));
    }return 0;
    mysql_close(mysql);

}
int mysql_sekect(MYSQL *mysql,char *auf,char *buf){//查找数据
    char query[256]={0};
    sprintf(query,"select *from user where %s=('%s');\n",auf,buf);
    int qret=mysql_query(mysql,query);//把sql语句字符串发给服务端
    if(qret!=0){
        fprintf(stderr,"%s:%s\n","mysql_real_connect",mysql_error(mysql));
        exit(-1);
    }
        MYSQL_RES *table=mysql_store_result(mysql); //取表
        //int cols=mysql_num_fields(table); //列数
        long rows=mysql_num_rows(table);//行数
       /* printf("cols = %d,rows =%ld\n",cols,rows); */
        /* for(long i=0;i<rows;i++){ */
        /*     MYSQL_ROW row=mysql_fetch_row(table); */
        /*     for(int j=0;j<cols;j++){ */
        /*         printf("%s\t",row[j]); */
        /*     } */
        /*     printf("\n"); */
        /* } */

        mysql_free_result(table);
        mysql_close(mysql);
        //printf("rows=%ld\n",rows);
        return rows;

    
}
/* int mysql_delete(MYSQL *mysql,char *name){ // 修改数据(注销) */
/*     char query[256]={0}; */
/*     sprintf(query,"update user set tomb=1 where username='%s';\n",name); */
/*     int qret=mysql_query(mysql,query);//把sql语句字符串发给服务端 */
/*     if(qret!=0){ */
/*         fprintf(stderr,"%s:%s\n","mysql_real_connect",mysql_error(mysql)); */
/*     } */
/*     return 0; */

/* } */
/* int register_account(int netfd)  //注册 */
/* { */
/*     char handle[256]={0}; */
/*     printf("请输入一个用户:"); */
/*     fflush(stdout); */
/*     scanf("%s",handle); */
/*     fflush(stdout); */
/*     MYSQL *mysql=mysql_init(NULL); */
/*     mysql_database(mysql); */
/*     //入表 */
/*     mysql_add(mysql,handle); */
/*     bzero(handle,sizeof(handle)); */
/*     printf("请输入密码:"); */
/*     fflush(stdout); */
/*     scanf("%s",handle); */
   
/*     return 0; */
/* } */

/* int main(){ */ 
/*      MYSQL *mysql=mysql_init(NULL); */ 
/*      mysql_database(mysql); */
/*     // mysql_add(mysql,"zhou"); */
/*      mysql_sekect(mysql,"username","z"); */
/*      //mysql_delete(mysql,"zhou"); */
/*      return 0; */
/* } */







